/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package API_Db;

import java.sql.*;

/**
 * @author Damador
 */
public class API_Db_Compte implements IAPI_Db_Compte {

    @Override
    public int crediterCompteDB(int id_utilisateur, double montant) throws Exception {
        ConnexionDB connect = ConnexionDB.getConnexion();

        String requeteUpdateUtilisateur = "UPDATE compte SET solde = solde + "+montant+" WHERE id_utilisateur = " + id_utilisateur;

        return connect.executerRequeteUpdate(requeteUpdateUtilisateur);
    }
   
    @Override
    public int debiterCompteDB(int id_utilisateur, double montant) throws Exception {
        ConnexionDB connect = ConnexionDB.getConnexion();

        String requeteUpdateUtilisateur = "UPDATE compte SET solde = solde - "+montant+" WHERE id_utilisateur = " + id_utilisateur;

        return connect.executerRequeteUpdate(requeteUpdateUtilisateur);
    }

    @Override
    public double getSoldeCompteDB(int id_utilisateur) throws Exception {
        ConnexionDB connect = ConnexionDB.getConnexion();
        ResultSet res;

        String requetegetsolde = "SELECT solde FROM compte WHERE id_utilisateur=" + id_utilisateur +";";
        res = connect.executerRequeteQuery(requetegetsolde);

        if (res.next()) {
            return res.getDouble("solde");
        }
        return -1;
    }

    @Override
    public int cloturerCompteDB(int id_utilisateur) throws Exception {
        ConnexionDB connect = ConnexionDB.getConnexion();

        String requeteUpdateUtilisateur = "UPDATE compte SET solde = 0 WHERE id_utilisateur = " + id_utilisateur;

        return connect.executerRequeteUpdate(requeteUpdateUtilisateur);

    }
}
